Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Enhancement] Limit memory used by ParallelIterable in Iceberg #54219

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

zhaohehuhu
Copy link
Contributor

@zhaohehuhu zhaohehuhu commented Dec 23, 2024

Why I'm doing:

The ConcurrentLinkedQueue doesn't have a size limitation in Iceberg 1.6.0. When the iceberg table is large, the queue will also become really large, which will cause OOM in the FE.

image

As per the above screenshot, the ConcurrentLinkedQueue is consuming 91%+ of the heap memory and causing the Frontend (FE) to go down, this indicates a significant memory management issue due to unbounded growth of the queue.

This issue was resolved with Iceberg 1.6.1(#10691)

What I'm doing:

as title

What type of PR is this:

  • BugFix
  • Feature
  • Enhancement
  • Refactor
  • UT
  • Doc
  • Tool

Does this PR entail a change in behavior?

  • Yes, this PR will result in a change in behavior.
  • No, this PR will not result in a change in behavior.

If yes, please specify the type of change:

  • Interface/UI changes: syntax, type conversion, expression evaluation, display information
  • Parameter changes: default values, similar parameters but with different default values
  • Policy changes: use new policy to replace old one, functionality automatically enabled
  • Feature removed
  • Miscellaneous: upgrade & downgrade compatibility, etc.

Checklist:

  • I have added test cases for my bug fix or my new feature
  • This pr needs user documentation (for new or modified features or behaviors)
    • I have added documentation for my new feature or new function
  • This is a backport pr

Bugfix cherry-pick branch check:

  • I have checked the version labels which the pr will be auto-backported to the target branch
    • 3.4
    • 3.3
    • 3.2
    • 3.1
    • 3.0

@zhaohehuhu
Copy link
Contributor Author

zhaohehuhu commented Dec 23, 2024

@stephen-shelby @Youngwb plz help review

@zhaohehuhu zhaohehuhu changed the title Upgrade Iceberg to 1.6.1 to limit memory used by ParallelIterable [Enhancement] Upgrade Iceberg to 1.6.1 to limit memory used by ParallelIterable Dec 23, 2024
gengjun-git
gengjun-git previously approved these changes Dec 24, 2024
@zhaohehuhu zhaohehuhu changed the title [Enhancement] Upgrade Iceberg to 1.6.1 to limit memory used by ParallelIterable [Enhancement] Limit memory used by ParallelIterable in Iceberg Dec 27, 2024
Copy link

[FE Incremental Coverage Report]

pass : 0 / 0 (0%)

@stephen-shelby
Copy link
Contributor

how many manifest files and data files in your case? I think if you use version 3.3 or above, this case may go to distributed plan, not local plan.

@zhaohehuhu
Copy link
Contributor Author

how many manifest files and data files in your case? I think if you use version 3.3 or above, this case may go to distributed plan, not local plan.
Total Size of metadata is 439MB, while data files occupies 2TB space. Iceberg already released 1.6.1 to fix this issue, so it would be nice for us to update the version of Iceberg.

@stephen-shelby
Copy link
Contributor

how many manifest files and data files in your case? I think if you use version 3.3 or above, this case may go to distributed plan, not local plan.
Total Size of metadata is 439MB, while data files occupies 2TB space. Iceberg already released 1.6.1 to fix this issue, so it would be nice for us to update the version of Iceberg.

could you try to set plan_mode=distributed then retry this query? you can observe if memory still high

@gengjun-git
Copy link
Contributor

@Mergifyio rebase

Copy link
Contributor

mergify bot commented Jan 3, 2025

rebase

✅ Branch has been successfully rebased

Copy link

sonarqubecloud bot commented Jan 3, 2025

@zhaohehuhu
Copy link
Contributor Author

how many manifest files and data files in your case? I think if you use version 3.3 or above, this case may go to distributed plan, not local plan.
Total Size of metadata is 439MB, while data files occupies 2TB space. Iceberg already released 1.6.1 to fix this issue, so it would be nice for us to update the version of Iceberg.

could you try to set plan_mode=distributed then retry this query? you can observe if memory still high

OK. I will take a try.

Copy link

github-actions bot commented Jan 3, 2025

[Java-Extensions Incremental Coverage Report]

pass : 0 / 0 (0%)

Copy link

github-actions bot commented Jan 3, 2025

[BE Incremental Coverage Report]

pass : 0 / 0 (0%)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants